package com.sx.sx1.tools;

import java.util.Arrays;
import java.util.List;

public class SFTPReader1024 {


    public static void main(String[] args) {

    }


    public static void sycybxquestiondata() {
        System.out.println("准备同步银保信检核工具的问题数据");

        try {

            //select  DISTINCT(ybx_job_id)  from dc_job_batch where ybx_job_id not in(
            //select   DISTINCT(t1.ybx_job_id) from dc_job_batch t1 INNER JOIN east_error_list_ybx t2 on t1.ybx_job_id=t2.job_id
            //where t1.ybx_job_id is not null
            //) order by ybx_job_id desc

            //File sftpdir = new File(uploadpath+"/sftp/");
//
//
//            // 判断目录是否存在，如果不存在则尝试创建
//            if (!sftpdir.exists()) {
//                // 创建目录
//                boolean succ = sftpdir.mkdir();
//
//                if (succ) {
//                    log.info(uploadpath+"/sftp/"+"  检核工具问题数据文件存放目录 Directory created successfully");
//                } else {
//                    log.info(uploadpath+"/sftp/"+ "  检核工具问题数据文件存放目录 Failed to create directory");
//                }
//            } else {
//                log.info(uploadpath+"/sftp/" + "   检核工具问题数据文件存放目录 Directory already exists");
//                //continue; //说明之前已经同步过这个任务去的文件了
//            }

            //传输文件
            List<Integer> syncybxids = Arrays.asList(1319,1320);
            if(syncybxids!=null && syncybxids.size() >0) {
                //----sftp传输文件开始
                for (Integer jobid : syncybxids) {

                }
            }
//            //syncybxids =Arrays.asList(1319,1320);
//            if(syncybxids!=null && syncybxids.size() >0) {
//                //----sftp传输文件开始
//                for (Integer jobid : syncybxids) {
//
//                    String remoteFiledir = sftpremotePath+"/"+ jobid;
//                    String localFiledir = uploadpath+"/sftp/"+jobid;
//
//                    // 创建一个表示新目录的File对象
//                    File newDirectory = new File(localFiledir);
//
//                    // 判断目录是否存在，如果不存在则尝试创建
//                    if (!newDirectory.exists()) {
//                        // 创建目录
//                        boolean wasSuccessful = newDirectory.mkdir();
//
//                        if (wasSuccessful) {
//                            log.info(localFiledir+"  Directory created successfully");
//                        } else {
//                            log.info(localFiledir+ "  Failed to create directory");
//                        }
//                    } else {
//                        log.info(localFiledir + "   Directory already exists");
//                        continue; //说明之前已经同步过这个任务去的文件了
//                    }
//
//                    // public SFTPUtils(String hostname, int port, String username, String password,String rpath,String lopath) {
//
//                    SFTPUtils sftpUtils = new SFTPUtils(sftmphost,sftpport,sftpusername,sftppassword,remoteFiledir,localFiledir);
//                    sftpUtils.transferfile();
//
//                    if(!sftpUtils.isdownsucc) {
//                        newDirectory.delete(); //远程不存在目录，本地给他删除
//                    }
//                }
//                //----sftp传输文件结束
//            }

            //读取文件，插入到高斯和ORACLE的问题数据表
            //List<Integer> list = syncYBXService.syncybxquestiondata();

            //从oraclec获取问题数据的清单，更新east_error_list_ybx表的清单字段
          //  syncYBXService.syncYBXQSqingdan(list, get46table());
        } catch (Exception e) {
            e.printStackTrace();
            //log.info("准备同步银保信检核工具的问题数据:出现异常了,异常信息如下：");
            //log.info(e + "");
        }
    }
}
